package cn.monkey.transport.core;

import reactor.core.publisher.Mono;

public interface ReactiveExchangeManager<C, EXCHANGE extends Exchange> {

    Mono<EXCHANGE> findOrCreate(String key, C c);

    Mono<Void> destroy(EXCHANGE exchange);
}
